package com.icarbonx.dap.notification.util

/**
 * Created by Lenovo on 2018/8/23.
 */
object KafkaUtil {
  def getKafkaParam(brokers: String, group: String): Map[String, String] = {
    Map("metadata.broker.list" -> brokers,
      "group.id" -> group
      //      "auto.offset.reset" -> "earliest"
//      ,  "auto.offset.reset" -> "smallest"
    )
  }
}
